"""
flask-sqlalchemy 提供了两种更新数据的方案:
    1.先查询, 再更新
        对应SQL中的 先select, 再update
    2.基于过滤条件的更新 (推荐方案)
        对应SQL中的 update xx where xx = xx (也称为 update子查询 )
"""
"""
1.先查询, 再更新
    这种方式简单易懂, 操作步骤如下:
        执行查询语句, 获取目标模型对象
        对模型对象的属性进行赋值 (更新数据)
        提交会话
    
    缺点:
        查询和更新分两条语句, 效率低
        如果并发更新, 可能出现更新丢失问题(Lost Update)
"""
# from flask import Flask
# from flask_sqlalchemy import SQLAlchemy
#
# app = Flask(__name__)
#
# # 相关配置
# app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://root:mysql@127.0.0.1:3306/Test'
# app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False
# app.config['SQLALCHEMY_ECHO'] = True
#
# # 创建组件对象
# db = SQLAlchemy(app)
#
#
# # 构建模型类  商品表
# class Goods(db.Model):
#     __tablename__ = 't_good'  # 设置表名
#     id = db.Column(db.Integer, primary_key=True)  # 设置主键
#     name = db.Column(db.String(20), unique=True)  # 商品名称
#     count = db.Column(db.Integer)  # 剩余数量
#
#
# @app.route('/')
# def purchase():
#     """购买商品"""
#
#     # 更新方式1: 先查询后更新
#     # 缺点: 并发情况下, 容易出现更新丢失问题 (Lost Update)
#
#     # 1.执行查询语句, 获取目标模型对象
#     goods = Goods.query.filter(Goods.name == '方便面').first()
#     # 2.对模型对象的属性进行赋值 (更新数据)
#     goods.count = goods.count - 1
#     # 3.提交会话
#     db.session.commit()
#
#     return "index"
#
#
# if __name__ == '__main__':
#     # 删除所有继承自db.Model的表
#     db.drop_all()
#     # 创建所有继承自db.Model的表
#     db.create_all()
#
#     # 添加一条测试数据
#     goods = Goods(name='方便面', count=1)
#     db.session.add(goods)
#     db.session.commit()
#     app.run(debug=True)


"""
2.基于过滤条件的更新
    优点:
        一条语句, 被网络IO影响程度低, 执行效率更高
        查询和更新在一条语句中完成, 单条SQL具有原子性, 不会出现更新丢失问题
        会对满足过滤条件的所有记录进行更新, 可以实现批量更新处理
    操作步骤如下:
        配合 查询过滤器filter() 和 更新执行器update() 进行数据更新
        提交会话
"""
from flask import Flask
from flask_sqlalchemy import SQLAlchemy

app = Flask(__name__)

# 相关配置
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://root:mysql@127.0.0.1:3306/Test'
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False
app.config['SQLALCHEMY_ECHO'] = True

# 创建组件对象
db = SQLAlchemy(app)


# 构建模型类  商品表
class Goods(db.Model):
    __tablename__ = 't_good'
    id = db.Column(db.Integer, primary_key=True)
    name = db.Column(db.String(20), unique=True)
    count = db.Column(db.Integer)


@app.route('/')
def purchase():
    """购买商品"""

    # 更新方式2: update子查询   可以避免更新丢失问题
    # update t_good set count = count - 1 where name = '方便面';
    Goods.query.filter(Goods.name == '方便面').update({'count': Goods.count - 1})
    # 提交会话
    db.session.commit()
    return "index"


if __name__ == '__main__':
    # 重置数据库数据
    db.drop_all()
    db.create_all()

    # 添加一条测试数据
    goods = Goods(name='方便面', count=1)
    db.session.add(goods)
    db.session.commit()
    app.run(debug=True)
